//package com.zhang.abandon;
//
//import cn.hutool.json.JSONObject;
//import cn.hutool.json.JSONUtil;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.stereotype.Component;
//
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.PathParam;
//import javax.websocket.server.ServerEndpoint;
//import java.util.Map;
//import java.util.concurrent.ConcurrentHashMap;
//
///**
// * @Version: v1.0
// * @ClassName: WebSocketServer
// * @Description：
// * @Author: zhangconglong on 2021/11/16
// */
//@Component
//@ServerEndpoint(value = "/imserver/{username}")
//public class WebSocketServer {
//
//    private static final Logger logger = LoggerFactory.getLogger(WebSocketServer.class);
//    /*记录在线链接数*/
//    public static final Map<String, Session> sessionMap = new ConcurrentHashMap<>();
//
//    /*连接建立成功调用的方法*/
//    @OnOpen
//    public void onOpen(Session session, @PathParam("username")String usename){
//        sessionMap.put(usename, session);
//        logger.info("有新用户加入，username={}，当前在线人数为：{}", usename ,sessionMap.size());
//        JSONObject jsonObject = JSONUtil.parseObj();
//
//    }
//
//    /**
//     * 接受到客户端消息调用的方法
//     * @param message
//     */
//    @OnMessage
//    public void onMessage(String message, javax.websocket.Session session, @PathParam("username")String username){
//
//        JSONObject jsonObject = JSONUtil.parseObj(message);
//        String toUsername = jsonObject.getStr("to"); //to表示发送给那个用户
//        String text = jsonObject.getStr("text"); //发送文本
//        logger.info("服务端收到用户：username={}的消息：{}", username ,message);
//
//
//    }
//}
